package util;

/**
 * @author yue.cao
 * @since 10-14-2020
 */
public interface FlinkConstant {


	interface  _ENV{
		String PRODUCTION = "PRODUCTION";
		String DEV = "DEV";
	}

	interface _Flink {
		String FSSTATE_BACK_END_PATH ="file:///G:/giteeWorkspace/FlinkLearn/backend";
	}

	interface _Kafka {
		interface _Topic {
			String CY1 = "cy1";
			String CY3 = "cy3";
			String CY4 = "cy4";
		}

		interface _Server {
			String BOOTSTRAP_SERVERS = "caoyuesh4:9092,caoyuesh5:9092";
		}

		interface _Group_id {
			String COMMON = "cyGroupId";
		}
	}

	interface _MySQL {
		String URL = "jdbc:mysql://10.199.170.214:3306/cyflink?characterEncoding=utf-8";
		String USER_NAME = "vipshop";
		String PASSWORD = "dWwkv%+!1cQf$FNy";
	}


	interface _Common {
		Integer[] FROM_0_TO_10 = {0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10};
		String[] SOME_STRING_WITH_SPACE = {"spark flink hadoop", "flink storm spark"};
		String[] SOME_STRING = {"spark", "flink", "hadoop", "flink", "storm", "spark"};
	}

}
